package cn.codenest.util.kafka;

import org.apache.kafka.clients.consumer.ConsumerRebalanceListener;
import org.apache.kafka.clients.consumer.KafkaConsumer;

/**
 * <h3>kafka-ts</h3>
 * <p></p>
 *
 * @author : Hyman
 * @date : 2021-06-30 17:35
 **/
public interface KafkaConsumerService {

    /**
     * create by: Hyman
     * description: 轮训的方式处理消息
     * create time: 2021/6/30
     */
    void handle(String topic);

}
